package com.zst.amqp.entity;

import org.springframework.amqp.rabbit.support.CorrelationData;

/**
 * 消息队列发送确认关联数据类
 * 用于在发送消息时作为消息的额外内容发送给消息队列，当消息队列发送确认收到消息回调时会携带此数据调用回调方法
 * @author zst
 */
public class PublisherCorrelationData extends CorrelationData {
    /**
     * 生产者确认函数的key
     */
    private String key;

    public String getKey() {
        return key;
    }

    public void setKey(String key) {
        this.key = key;
    }

    /**
     * 实例化
     * @param correlationId
     * @param key
     * @return
     */
    public static PublisherCorrelationData build(String correlationId, String key) {
        PublisherCorrelationData data = new PublisherCorrelationData();
        data.setId(correlationId);
        data.setKey(key);
        return data;
    }
}
